package com.xydpeng.rpc.consumer.handler;

import com.xydpeng.rpc.common.model.FastRpcResponse;
import com.xydpeng.rpc.protocol.FastRpcProtocol;
import com.xydpeng.rpc.protocol.MsgHeader;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;

/**
 * @author xydpeng
 * @version v1.0
 * @date: 2023/4/14
 * @description:
 */
public class RpcResponseHandler extends SimpleChannelInboundHandler<FastRpcProtocol<FastRpcResponse>> {
    @Override
    protected void channelRead0(ChannelHandlerContext ctx, FastRpcProtocol<FastRpcResponse> msg) throws Exception {
        MsgHeader header = msg.getHeader();
        FastRpcResponse response = msg.getBody();
        long requestId = header.getRequestId();


    }
}
